org.springframework.web.context.request.async

Class WebAsyncTask<V>

java.lang.Object

org.springframework.web.context.request.async.WebAsyncTask<V>

All Implemented Interfaces:

Aware, BeanFactoryAware

public class WebAsyncTask<V>
extends java.lang.Object
implements BeanFactoryAware

Holder for a Callable, a timeout value, and a task executor.

Since:

3.2

Author:

Rossen Stoyanchev, Juergen Hoeller

Field Summary

Fields

Modifier and Type	Field and Description
private BeanFactory	beanFactory
private java.util.concurrent.Callable<V>	callable
private java.lang.Runnable	completionCallback
private AsyncTaskExecutor	executor
private java.lang.String	executorName
private java.lang.Long	timeout
private java.util.concurrent.Callable<V>	timeoutCallback

Constructor Summary

Constructors

Constructor and Description
WebAsyncTask(java.util.concurrent.Callable<V> callable) Create a WebAsyncTask wrapping the given Callable.
WebAsyncTask(java.lang.Long timeout, AsyncTaskExecutor executor, java.util.concurrent.Callable<V> callable) Create a WebAsyncTask with a timeout value, an executor instance, and a Callable.
WebAsyncTask(long timeout, java.util.concurrent.Callable<V> callable) Create a WebAsyncTask with a timeout value and a Callable.
WebAsyncTask(java.lang.Long timeout, java.lang.String executorName, java.util.concurrent.Callable<V> callable) Create a WebAsyncTask with a timeout value, an executor name, and a Callable.

Method Summary

Methods

Modifier and Type	Method and Description
java.util.concurrent.Callable<?>	getCallable() Return the Callable to use for concurrent handling (never null).
AsyncTaskExecutor	getExecutor() Return the AsyncTaskExecutor to use for concurrent handling, or null if none specified.
(package private) CallableProcessingInterceptor	getInterceptor()
java.lang.Long	getTimeout() Return the timeout value in milliseconds, or null if no timeout is set.
void	onCompletion(java.lang.Runnable callback) Register code to invoke when the async request completes.
void	onTimeout(java.util.concurrent.Callable<V> callback) Register code to invoke when the async request times out.
void	setBeanFactory(BeanFactory beanFactory) A BeanFactory to use for resolving an executor name.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

callable

private final java.util.concurrent.Callable<V> callable

timeout

private java.lang.Long timeout

executor

private AsyncTaskExecutor executor

executorName

private java.lang.String executorName

beanFactory

private BeanFactory beanFactory

timeoutCallback

private java.util.concurrent.Callable<V> timeoutCallback

completionCallback

private java.lang.Runnable completionCallback

Constructor Detail

WebAsyncTask

public WebAsyncTask(java.util.concurrent.Callable<V> callable)

Create a WebAsyncTask wrapping the given Callable.

Parameters:

callable - the callable for concurrent handling

WebAsyncTask

public WebAsyncTask(long timeout,
            java.util.concurrent.Callable<V> callable)

Create a WebAsyncTask with a timeout value and a Callable.

Parameters:

timeout - a timeout value in milliseconds

callable - the callable for concurrent handling

WebAsyncTask

public WebAsyncTask(java.lang.Long timeout,
            java.lang.String executorName,
            java.util.concurrent.Callable<V> callable)

Create a WebAsyncTask with a timeout value, an executor name, and a Callable.

Parameters:

timeout - timeout value in milliseconds; ignored if null

executorName - the name of an executor bean to use

callable - the callable for concurrent handling

WebAsyncTask

public WebAsyncTask(java.lang.Long timeout,
            AsyncTaskExecutor executor,
            java.util.concurrent.Callable<V> callable)

Create a WebAsyncTask with a timeout value, an executor instance, and a Callable.

Parameters:

timeout - timeout value in milliseconds; ignored if null

executor - the executor to use

callable - the callable for concurrent handling

Method Detail

getCallable

public java.util.concurrent.Callable<?> getCallable()

Return the Callable to use for concurrent handling (never null).

getTimeout

public java.lang.Long getTimeout()

Return the timeout value in milliseconds, or null if no timeout is set.

setBeanFactory

public void setBeanFactory(BeanFactory beanFactory)

A BeanFactory to use for resolving an executor name.

This factory reference will automatically be set when WebAsyncTask is used within a Spring MVC controller.

Specified by:

setBeanFactory in interface BeanFactoryAware

Parameters:

beanFactory - owning BeanFactory (never null). The bean can immediately call methods on the factory.

See Also:

BeanInitializationException

getExecutor

public AsyncTaskExecutor getExecutor()

Return the AsyncTaskExecutor to use for concurrent handling, or null if none specified.

onTimeout

public void onTimeout(java.util.concurrent.Callable<V> callback)

Register code to invoke when the async request times out.

This method is called from a container thread when an async request times out before the Callable has completed. The callback is executed in the same thread and therefore should return without blocking. It may return an alternative value to use, including an Exception or return RESULT_NONE.

onCompletion

public void onCompletion(java.lang.Runnable callback)

Register code to invoke when the async request completes.

This method is called from a container thread when an async request completed for any reason, including timeout and network error.

getInterceptor

CallableProcessingInterceptor getInterceptor()